package com.zookeeper.ref.balance;

/**
 * Author: dong peng
 * Date: 2018/1/23
 * Time: 15:24
 */


import java.util.ArrayList;
import java.util.List;

/**
 * 用于测试,负责启动Work Server
 */
public class ServerRunner {

    private static final int  SERVER_QTY = 2;
    private static final String  ZOOKEEPER_SERVER = "192.168.1.105:2181";
    private static final String  SERVERS_PATH = "/servers";

    public static void main(String[] args) {

        List<Thread> threadList = new ArrayList<Thread>();

        for(int i=0; i<SERVER_QTY; i++){

            final Integer count = i;
            Thread thread = new Thread(new Runnable() {

                public void run() {
                    ServerData sd = new ServerData();
                    sd.setBalance(0);
                    sd.setHost("127.0.0.1");
                    sd.setPort(6000+count);
                    Server server = new ServerImpl(ZOOKEEPER_SERVER,SERVERS_PATH,sd);
                    server.bind();
                }
            });
            threadList.add(thread);
            thread.start();
        }

        for (int i=0; i<threadList.size(); i++){
            try {
                threadList.get(i).join();
            } catch (InterruptedException ignore) {
                //
            }

        }


    }

}